import pymysql

class mysql():
    def __init__(self,host,user,password,database,port):
        self.con=pymysql.connect(host=host,user=user,password=password,database=database,port=port)
        self.cur=self.con.cursor()

    def select(self,sql):
        self.cur.execute(sql)
        return self.cur.fetchall()

    def delete(self, sql):
        """执行删除操作"""
        try: # 执行SQL删除语句
            self.cur.execute(sql)
            self.con.commit()  # 提交事务，确保删除操作生效
            return self.cur.rowcount  # 返回受影响的行数
        except Exception as e:
            self.con.rollback()  # 出现异常时回滚事务
            raise e  # 重新抛出异常
        finally:
            self.con.close()  # 最终关闭游标

    def close(self):
        self.cur.close()
        self.con.close()
